//package com.zhs.study.rocketMq.springboot;
//
//import com.zhs.study.rocketMq.constant.IndexConstant;
//import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
//import org.apache.rocketmq.spring.core.RocketMQListener;
//import org.springframework.stereotype.Service;
//
///**
// *
// * @Author zhenghuisheng
// * @Date：2025/4/21 21:22
// */
//@Service
//@RocketMQMessageListener(topic = IndexConstant.CUSTOM_TOPIC, consumerGroup = IndexConstant.CUSTOM_GROUP)
//public class MQConsumerService implements RocketMQListener<String> {
//
//    public void onMessage(String message) {
//        System.out.println("收到消息: " + message);
//    }
//
//}
